package net.com.client.test;

import java.io.IOException;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;

public class EmitLog {

    private static final String EXCHANGE_NAME = "logs";

    public static void main(String[] argv)
                  throws java.io.IOException {

        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        Connection connection = factory.newConnection();
        
        Channel channel = connection.createChannel();
        
        channel.exchangeDeclare(EXCHANGE_NAME, "fanout");

        String message = getMessage(argv);

        channel.basicPublish(EXCHANGE_NAME, "", null, message.getBytes());
        System.out.println(" [x] Sent '" + message + "'");

        channel.close();
        connection.close();
    }
	private static String getMessage(String[] strings) {
		if(strings.length<1)return "HelloWorld";
		return joinStrings(strings,"");
	}
	private static String joinStrings(String[] strings, String delimiter) {
		int length = strings.length;
		if(length==0) return "";
		StringBuilder words = new StringBuilder(strings[0]);
		for(int i=1;i<length;i++){
			words.append(strings[i]);
		}
		return words.toString();
	}
}
